package br.sc.senai.dao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import br.sc.senai.conexaoBanco.ConexaoMySQL;
import br.sc.senai.model.Produto;

public class ProdutoDAO {

	public Produto consultar(Integer idProduto) {
		try {
			Statement st = ConexaoMySQL.getConexaoMySQL().createStatement();
			String query = "SELECT * FROM produto WHERE idProduto = "
					+ idProduto + ";";
			ResultSet rs = st.executeQuery(query);
			Produto prod = new Produto();
			while (rs.next()) {
				prod = new Produto(idProduto, rs.getString("marca"),
						rs.getString("descricao"),
						rs.getDouble("precoUnitario"), rs.getInt("validade"));
			}
			return prod;
		} catch (SQLException e) {
			System.out.println("SQL Exception - dao.ProdutoDAO.consultar()");
			return null;
		}
	}
}
